package com.struggle.rabbitmqconsumer.listener.topic;

/**
 * @className TopicManReceiver
 * @Description TODO
 * @Author liuwj3
 * @Date 2019/10/12 0012 下午 4:00
 **/
/*@RabbitListener(queues = QueueConstants.TOPIC_QUEUE_FIRST)
@Component
public class TopicManReceiver {
    @RabbitHandler
    public void process(Map<String, Object> message) throws Exception {
        System.out.println(QueueConstants.TOPIC_QUEUE_FIRST + "收到消息：" + new ObjectMapper().writeValueAsString(message));
    }
}*/
